package org.niit.app

import org.apache.spark.sql.Dataset
import org.niit.common.TApp
import org.niit.controller.MovieDataController
import org.niit.util.SparkUtil

/**
 * Date:2025/6/5
 * Author：Ys
 * Description:
 */
object MovieOfflineApp extends TApp{
    val movieDataController = new MovieDataController()
  start("local[*]",  "MovieOfflineApp"){

    val ds: Dataset[String] = spark.read.textFile("input/rating_100k.data")

    movieDataController.dispatch(ds)
  }

}
